package cn.tedu.batch.transformation

import org.apache.flink.api.scala.ExecutionEnvironment

/**
 * @author Amos
 * @date 2022/5/20
 */

object BatchUnionDemo {
  def main(args: Array[String]): Unit = {
    val env = ExecutionEnvironment.getExecutionEnvironment
    import org.apache.flink.api.scala._

    val source1 = env.fromElements("hadoop", "hive", "flink")
    val source2 = env.fromElements("hadoop", "hive", "scala")
    val result: DataSet[String] = source1.union(source2)

    result.print()


  }

}
